package com.zpl.mq.consumer.api;

/**
 * @author zhupanlin
 * @version 1.0
 * @description: TODO
 * @date 2024/9/7 17:29
 */
public interface IMqConsumer {

    /**
     * 订阅
     * @param topicName topic 名称
     * @param tagRegex tagRegex 标签正则
     */
    void subscribe(String topicName, String tagRegex);

    /**
     * 注册监听器
     * @param listener 监听器
     */
    void registerListener(final IMqConsumerListener listener);
    
}
